//package org.example
//
///**
// * @author yangzhen14
// * @create 2021/4/20 12:47
// */
//object s {
//  def main(args: Array[String]): Unit = {
//    val resMap: Array[Map[String, Any]] = cache1.map(x => {
//      val info = x._2
//      val announceId = info(1)
//
//      val district: String = jObject.getOrDefault("district", "").toString
//
//      val enterprise: String = jObject.getOrDefault("enterprise", "").toString
//
//      val originalMsg: String = jObject.getOrDefault("originalMsg", "").toString
//
//      val vid: String = jObject.getOrDefault("vid", "").toString
//
//      val vin: String = jObject.getOrDefault("vin", "").toString
//
//      val commandSign: String = jObject.getOrDefault("commandSign", "").toString
//
//      Map(
//
//        "collectTime" -> cotime,
//
//        "district" -> district,
//
//        "enterprise" -> enterprise,
//
//        "originalMsg" -> originalMsg,
//
//        "vid" -> vid,
//
//        "vin" -> vin,
//
//        "commandSign" -> commandSign
//
//      )
//
//    }).filter(_ != null).collect()
//  }
//}
